fc0675d4e8268c55b38716f3a81e63522ce72bac,src/main/java/com/ociweb/pronghorn/network/ClientConnection.java,ClientConnection,registerForUse,#Selector#Pipe[]#boolean#,220

Before Change


				while (--i>=0) {
					Pipe<NetPayloadSchema> pipe = handshakeBegin[i];

					if (PipeWriter.tryWriteFragment(pipe, NetPayloadSchema.MSG_PLAIN_210) ) {
						
						PipeWriter.writeLong(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_CONNECTIONID_201, getId());
						PipeWriter.writeLong(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_POSITION_206, SSLUtil.HANDSHAKE_POS); //signal that WRAP is needed 
						PipeWriter.writeBytes(pipe, NetPayloadSchema.MSG_PLAIN_210_FIELD_PAYLOAD_204, EMPTY);
						PipeWriter.publishWrites(pipe);	
						
						//we did it, hurrah
						break;							

After Change


				while (--j>=0) {
						
					
					Pipe<NetPayloadSchema> pipe = handshakeBegin[c];
					assert(null!=pipe);
					
					if (Pipe.hasRoomForWrite(pipe)) {
					//	logger.info("request wrap for id {} to pipe {}",getId(), pipe);
						int size = Pipe.addMsgIdx(pipe, NetPayloadSchema.MSG_PLAIN_210);
						Pipe.addLongValue(getId(), pipe);
						Pipe.addLongValue(System.currentTimeMillis(), pipe);
						Pipe.addLongValue(SSLUtil.HANDSHAKE_POS, pipe);
						Pipe.addByteArray(EMPTY, 0, 0, pipe);
						Pipe.confirmLowLevelWrite(pipe, size);
						Pipe.publishWrites(pipe);
						
						//we did it, hurrah
						break;